#ifndef LOCKER_H
#define LOCKER_H

#include <pthread.h>
#include <semaphore.h>
#include <exception>



class Semaphore {
public:
    Semaphore() {
        if (sem_init(&m_sem, 0, 0) != 0) {
            throw std::exception();
        }
    }

    explicit Semaphore(int num) {
        if (sem_init(&m_sem, 0, num) != 0) {
            throw std::exception();
        }
    }

    ~Semaphore() {
        sem_destroy(&m_sem);
    }

    bool wait() {
        return sem_wait(&m_sem);
    }

    bool post() {
        return sem_post(&m_sem);
    }

private:
    sem_t m_sem;
};


class Locker {
public:
    Locker() {
        if (pthread_mutex_init(&m_mutex, nullptr) != 0){
            throw std::exception();
        }
    }

    ~Locker() {
        pthread_mutex_destroy(&m_mutex);
    }

    bool lock() {
        return pthread_mutex_lock(&m_mutex) == 0;
    }

    bool unlock() {
        return pthread_mutex_unlock(&m_mutex) == 0;
    }

    pthread_mutex_t *get() {
        return &m_mutex;
    }

private:
    pthread_mutex_t m_mutex;
};


class Condition {
public:
    Condition() {
        if (pthread_condattr_init(&m_condattr) != 0) {
            throw std::exception();
        }
        pthread_condattr_setclock(&m_condattr,CLOCK_MONOTONIC);
        if (pthread_cond_init(&m_cond, &m_condattr) != 0) {
            throw std::exception();
        }
    }

    ~Condition() {
        pthread_cond_destroy(&m_cond);
    }

    bool wait(pthread_mutex_t *mutex) {
        return pthread_cond_wait(&m_cond, mutex) == 0;
    }

    bool timedwait(pthread_mutex_t *mutex, struct timespec t) {
        return pthread_cond_timedwait(&m_cond, mutex, &t) == 0;
    }

    bool signal() {
        return pthread_cond_signal(&m_cond) == 0;
    }

    bool broadcast() {
        return pthread_cond_broadcast(&m_cond) == 0;
    }

private:
    pthread_cond_t m_cond;
    pthread_condattr_t m_condattr;
};


#endif // LOCKER_H
